Node / mirrors / MeshChatX / files / tests / backend / test_websocket_server_fd_oracle.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""Oracle: WebsocketServerInterface drops Transport refs after client disconnect."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72from T7ee787unittestT7ee787.T7ee787mock Tff7b72import Te6edf3MagicMockTb4b4b4, Te6edf3patch

Tff7b72from T7ee787meshchatxT7ee787.T7ee787srcT7ee787.T7ee787backendT7ee787.T7ee787interfacesT7ee787.T7ee787WebsocketServerInterface Tff7b72import Tb4b4b4(

Te6edf3WebsocketServerInterfaceTb4b4b4,

Tb4b4b4)

Tff7b72def Td2a8fftest_server_client_disconnect_removes_transport_interfaceTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3owner Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)

Te6edf3config Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6ffnameTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffws-serverTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6fflisten_ipTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6fflisten_portTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ff9Ta5d6ff"Tb4b4b4,

Tb4b4b4}

Te6edf3fake_ws Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)

Te6edf3fake_wsTff7b72.Td2a8ffremote_address Tff7b72= Tb4b4b4(Ta5d6ff"Ta5d6ff127.0.0.1Ta5d6ff"Tb4b4b4, T79c0ff12345Tb4b4b4)

Te6edf3transport_interfacesTb4b4b4: Tffa657list Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72class T56d364_ChildTb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Tff7b72*Te6edf3_argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3_kwargsTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffIN Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffOUT Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffHW_MTU Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffbitrate Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffmode Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffparent_interface Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffonline Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffannounce_rate_target Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffannounce_rate_grace Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffannounce_rate_penalty Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffdetached Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffread_loop_calls Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffdetach_calls Tff7b72= T79c0ff0

Tff7b72def Tff7b72__str__Tb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Ta5d6ff"Ta5d6ffChildTa5d6ff"

Tff7b72def Td2a8ffread_loopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffread_loop_calls Tff7b72+Tff7b72= T79c0ff1

Tff7b72def Td2a8ffdetachTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffdetach_calls Tff7b72+Tff7b72= T79c0ff1

Tff7b72selfTff7b72.Td2a8ffdetached Tff7b72= Tff7b72True

Te6edf3reticulum Tff7b72= Te6edf3MagicMockTb4b4b4(Tb4b4b4)

Te6edf3reticulumTff7b72.Td2a8ff_default_ic_max_held_announcesTff7b72.Td2a8ffreturn_value Tff7b72= T79c0ff256

Tff7b72with Tb4b4b4(

Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffRNS.ReticulumTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3mock_rnsTb4b4b4,

Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffRNS.Interfaces.Interface.Interface.get_config_objTa5d6ff"Tb4b4b4, Te6edf3return_valueTff7b72=Te6edf3configTb4b4b4)Tb4b4b4,

Te6edf3patchTb4b4b4(

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.interfaces.WebsocketServerInterface.threading.ThreadTa5d6ff"Tb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6ffRNS.TransportTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3mock_transportTb4b4b4,

Tb4b4b4)Tb4b4b4:

Te6edf3mock_rnsTff7b72.Td2a8ffget_instanceTff7b72.Td2a8ffreturn_value Tff7b72= Te6edf3reticulum

Te6edf3mock_transportTff7b72.Td2a8ffinterfaces Tff7b72= Te6edf3transport_interfaces

Te6edf3server Tff7b72= Te6edf3WebsocketServerInterfaceTb4b4b4(Te6edf3ownerTb4b4b4, Te6edf3configTb4b4b4)

Tff7b72with Te6edf3patchTb4b4b4(

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.interfaces.WebsocketServerInterface.WebsocketClientInterfaceTa5d6ff"Tb4b4b4,

Te6edf3side_effectTff7b72=Tff7b72lambda Tff7b72*Te6edf3aTb4b4b4, Tff7b72*Tff7b72*Te6edf3kTb4b4b4: Te6edf3_ChildTb4b4b4(Tb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4:

Te6edf3captured Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72def Td2a8fffake_serveTb4b4b4(Te6edf3handlerTb4b4b4, Tff7b72*Te6edf3_argsTb4b4b4, Tff7b72*Tff7b72*Te6edf3_kwargsTb4b4b4)Tb4b4b4:

Te6edf3capturedTb4b4b4[Ta5d6ff"Ta5d6ffhandlerTa5d6ff"Tb4b4b4] Tff7b72= Te6edf3handler

Tff7b72class T56d364_CtxTb4b4b4:

Tff7b72def Tff7b72__enter__Tb4b4b4(Te6edf3self_innerTb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3MagicMockTb4b4b4(Te6edf3serve_foreverTff7b72=Te6edf3MagicMockTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72def Tff7b72__exit__Tb4b4b4(Te6edf3self_innerTb4b4b4, Tff7b72*Te6edf3_excTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72False

Tff7b72return Te6edf3_CtxTb4b4b4(Tb4b4b4)

Tff7b72with Te6edf3patchTb4b4b4(

Ta5d6ff"Ta5d6ffmeshchatx.src.backend.interfaces.WebsocketServerInterface.serveTa5d6ff"Tb4b4b4,

Te6edf3side_effectTff7b72=Te6edf3fake_serveTb4b4b4,

Tb4b4b4)Tb4b4b4:

Te6edf3serverTff7b72.Td2a8ffdetached Tff7b72= Tff7b72False

Tff7b72def Td2a8ffstop_after_oneTb4b4b4(Tff7b72*Te6edf3_aTb4b4b4, Tff7b72*Tff7b72*Te6edf3_kTb4b4b4)Tb4b4b4:

Te6edf3serverTff7b72.Td2a8ffdetached Tff7b72= Tff7b72True

Tff7b72with Te6edf3patchTb4b4b4(Ta5d6ff"Ta5d6fftime.sleepTa5d6ff"Tb4b4b4, Te6edf3side_effectTff7b72=Te6edf3stop_after_oneTb4b4b4)Tb4b4b4:

Te6edf3serverTff7b72.Td2a8ffserveTb4b4b4(Tb4b4b4)

Tff7b72assert Ta5d6ff"Ta5d6ffhandlerTa5d6ff" Tff7b72in Te6edf3captured

Te6edf3before Tff7b72= Tffa657lenTb4b4b4(Te6edf3mock_transportTff7b72.Td2a8ffinterfacesTb4b4b4)

Te6edf3capturedTb4b4b4[Ta5d6ff"Ta5d6ffhandlerTa5d6ff"Tb4b4b4]Tb4b4b4(Te6edf3fake_wsTb4b4b4)

Tff7b72assert Tffa657lenTb4b4b4(Te6edf3mock_transportTff7b72.Td2a8ffinterfacesTb4b4b4) Tff7b72== Te6edf3before

Tff7b72assert Te6edf3serverTff7b72.Td2a8ffspawned_interfaces Tff7b72== Tb4b4b4[Tb4b4b4]